package com.lh.common.utils;

import java.util.concurrent.Callable;
import java.util.concurrent.CyclicBarrier;

/**
 * AsyncRequestUtils callable 的代理类
 *
 * @param <V>
 * @author lj
 */
class AsyncRequestCallableProxy<V> implements Callable<V> {
    private Callable<V> callable;
//    private CyclicBarrier cb;

    public AsyncRequestCallableProxy(Callable<V> callable) {
        this.callable = callable;
//        this.cb = cb;
    }

    @Override
    public V call() throws Exception {
        try {
            return callable.call();
        } finally {
//            this.cb.await();
        }
    }
}
